package cn.dapeng.rocket.message;

import cn.dapeng.rocket.config.RocketTemplate;

/**
 * @BelongProject rocket-shop
 * @BelongPackage cn.dapeng.message
 * @Description TODO
 * @ClassName RocketMessageOperate
 * @Author xupenghong
 * @Date 2024/6/27 15:02
 * @Version 1.0.0
 */
public class RocketMessageOperate implements MessageOperate {

    private final RocketTemplate rocketTemplate;

    public RocketMessageOperate(RocketTemplate rocketTemplate) {
        this.rocketTemplate = rocketTemplate;
    }

    @Override
    public void sendMessage(String message) {
        rocketTemplate.print();
        System.out.println("rocket发送消息：" + message);
    }

}
